d330d40665a3b42744db20dfc5d9a80ad5f9b439,core/src/test/java/org/apache/oozie/service/TestZKLocksService.java,TestZKLocksService,testReentrantMultipleCall,#,440
Before Change
zkls.init(Services.get());
ZKLockToken lock = (ZKLockToken) zkls.getWriteLock(path, 5000);
lock = (ZKLockToken) zkls.getWriteLock(path, 5000);
lock = (ZKLockToken) zkls.getWriteLock(path, 5000);
assertTrue(zkls.getLocks().containsKey(path));
lock.release();
assertTrue(zkls.getLocks().containsKey(path));
After Change
ZKLocksService zkls = new ZKLocksService();
try {
zkls.init(Services.get());
ZKLockToken lock = (ZKLockToken) zkls.getWriteLock(path, TestMemoryLocks.DEFAULT_LOCK_TIMEOUT);
lock = (ZKLockToken) zkls.getWriteLock(path, TestMemoryLocks.DEFAULT_LOCK_TIMEOUT);
lock = (ZKLockToken) zkls.getWriteLock(path, TestMemoryLocks.DEFAULT_LOCK_TIMEOUT);
assertTrue(zkls.getLocks().containsKey(path));